package com.xes.demo;


import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @program: tal-scsdemo
 * @description:
 * @author: pkn
 * @create: 2020-06-22 14:15
 */

public interface TalSink {

    @Input("input1")
    SubscribableChannel input1();

    @Input("input2")
    SubscribableChannel input2();

}
